import sqlite3
# 数据库文件名
db_name = 'export_jiaoyi.db'

# 假设这是你从爬取中得到的数据列表，每个元素是一个包含字段的元组或列表
# 注意：这里我们使用了元组作为示例
# data_to_insert = [
#     ('Item1', 'This is a description of Item1', 19.99),
#     ('Item2', 'Description of Item2', 29.99),
#     ('Item3', 'Detailed description for Item3', 39.99),
# ]

def insert(data_to_inserts):
    # 连接到SQLite数据库
    # 如果数据库不存在，会自动在当前目录创建
    conn = sqlite3.connect(db_name)
    # 创建一个Cursor对象并使用它执行SQL查询
    c = conn.cursor()
    # 创建表，如果表已存在则忽略（这里使用了CREATE TABLE IF NOT EXISTS）
    c.execute('''CREATE TABLE IF NOT EXISTS house_info  
                 (id INTEGER PRIMARY KEY AUTOINCREMENT,  
                  name TEXT NOT NULL, 
                  geju TEXT , 
                  area TEXT , 
                  desc TEXT,  
                  img TEXT, 
                  totalPrice real,
                  unitPrice integer,
                  guapaiPrice real,
                  chengjiao_days integer,
                  jiaoyi_date TEXT)''')

    # 遍历数据，并插入到表中
    for item in data_to_inserts:
        # 将字典转换为适合插入SQL语句的格式
        columns = ', '.join(item.keys())
        placeholders = ', '.join(['?'] * len(item))
        # 插入数据
        c.execute(f"INSERT INTO house_info ({columns}) VALUES ({placeholders})", tuple(item.values()))

        # 提交事务
    conn.commit()

    # # 关闭连接
    conn.close()
    #
    # print("数据已成功插入到SQLite数据库中。")

